--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
tests/frontend/WebSocketConnection.test.js bce42bcdce0e7d2c6d78228e864a4cd1d974cc82 (bce42bcd) Text, 18.32 KB
Tff7b72import Tb4b4b4{ Te6edf3afterEachTb4b4b4, Te6edf3beforeEachTb4b4b4, Te6edf3describeTb4b4b4, Te6edf3expectTb4b4b4, Te6edf3itTb4b4b4, Te6edf3vi Tb4b4b4} Tff7b72from Ta5d6ff"vitest"Tb4b4b4;
Tff7b72function Te6edf3makeWsImplTb4b4b4(Tb4b4b4) Tb4b4b4{
Tff7b72return Tff7b72class Te6edf3MockWebSocket Tb4b4b4{
Tff7b72static Te6edf3CONNECTING Tff7b72= T79c0ff0Tb4b4b4;
Tff7b72static Te6edf3OPEN Tff7b72= T79c0ff1Tb4b4b4;
Tff7b72static Te6edf3CLOSING Tff7b72= T79c0ff2Tb4b4b4;
Tff7b72static Te6edf3CLOSED Tff7b72= T79c0ff3Tb4b4b4;
Tff7b72constructorTb4b4b4(Te6edf3urlTb4b4b4) Tb4b4b4{
Tff7b72thisTb4b4b4.Te6edf3url Tff7b72= Te6edf3urlTb4b4b4;
Tff7b72thisTb4b4b4.Te6edf3readyState Tff7b72= Te6edf3MockWebSocketTb4b4b4.Te6edf3CONNECTINGTb4b4b4;
Tff7b72thisTb4b4b4.Te6edf3_listeners Tff7b72= Tb4b4b4{ Te6edf3openTff7b72: Tb4b4b4[Tb4b4b4]Tb4b4b4, Te6edf3closeTff7b72: Tb4b4b4[Tb4b4b4]Tb4b4b4, Te6edf3errorTff7b72: Tb4b4b4[Tb4b4b4]Tb4b4b4, Te6edf3messageTff7b72: Tb4b4b4[Tb4b4b4] Tb4b4b4}Tb4b4b4;
Te6edf3queueMicrotaskTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{
Tff7b72if Tb4b4b4(Tff7b72thisTb4b4b4.Te6edf3readyState Tff7b72=== Te6edf3MockWebSocketTb4b4b4.Te6edf3CLOSEDTb4b4b4) Tb4b4b4{
Tff7b72returnTb4b4b4;
Tb4b4b4}
Tff7b72thisTb4b4b4.Te6edf3readyState Tff7b72= Te6edf3MockWebSocketTb4b4b4.Te6edf3OPENTb4b4b4;
Tff7b72thisTb4b4b4.Te6edf3_listenersTb4b4b4.Te6edf3openTb4b4b4.Te6edf3forEachTb4b4b4(Tb4b4b4(Te6edf3fnTb4b4b4) Tb4b4b4=> Te6edf3fnTb4b4b4(Tb4b4b4)Tb4b4b4)Tb4b4b4;
Tb4b4b4}Tb4b4b4)Tb4b4b4;
Tb4b4b4}
Te6edf3addEventListenerTb4b4b4(Te6edf3typeTb4b4b4, Te6edf3fnTb4b4b4) Tb4b4b4{
Tff7b72thisTb4b4b4.Te6edf3_listenersTb4b4b4[Te6edf3typeTb4b4b4]Tff7b72?Tb4b4b4.Te6edf3pushTb4b4b4(Te6edf3fnTb4b4b4)Tb4b4b4;
Tb4b4b4}
Te6edf3sendTb4b4b4(Te6edf3dataTb4b4b4) Tb4b4b4{
Tff7b72if Tb4b4b4(Te6edf3dataTb4b4b4.Te6edf3includesTb4b4b4(Ta5d6ff'"type":"ping"'Tb4b4b4)Tb4b4b4) Tb4b4b4{
Te6edf3queueMicrotaskTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{
Tff7b72thisTb4b4b4.Te6edf3_listenersTb4b4b4.Te6edf3messageTb4b4b4.Te6edf3forEachTb4b4b4(Tb4b4b4(Te6edf3fnTb4b4b4) Tb4b4b4=> Te6edf3fnTb4b4b4(Tb4b4b4{ Te6edf3dataTff7b72: Tffa657JSONTb4b4b4.Te6edf3stringifyTb4b4b4(Tb4b4b4{ Te6edf3typeTff7b72: Ta5d6ff"pong" Tb4b4b4}Tb4b4b4) Tb4b4b4}Tb4b4b4)Tb4b4b4)Tb4b4b4;
Tb4b4b4}Tb4b4b4)Tb4b4b4;
Tb4b4b4}
Tb4b4b4}
Te6edf3closeTb4b4b4(Te6edf3codeTb4b4b4, Te6edf3reasonTb4b4b4) Tb4b4b4{
Tff7b72if Tb4b4b4(Tff7b72thisTb4b4b4.Te6edf3readyState Tff7b72=== Te6edf3MockWebSocketTb4b4b4.Te6edf3CLOSEDTb4b4b4) Tb4b4b4{
Tff7b72returnTb4b4b4;
Tb4b4b4}
Tff7b72thisTb4b4b4.Te6edf3readyState Tff7b72= Te6edf3MockWebSocketTb4b4b4.Te6edf3CLOSEDTb4b4b4;
Te6edf3queueMicrotaskTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{
Tff7b72thisTb4b4b4.Te6edf3_listenersTb4b4b4.Te6edf3closeTb4b4b4.Te6edf3forEachTb4b4b4(Tb4b4b4(Te6edf3fnTb4b4b4) Tb4b4b4=> Te6edf3fnTb4b4b4(Tb4b4b4{ Te6edf3codeTb4b4b4, Te6edf3reason Tb4b4b4}Tb4b4b4)Tb4b4b4)Tb4b4b4;
Tb4b4b4}Tb4b4b4)Tb4b4b4;
Tb4b4b4}
Tb4b4b4}Tb4b4b4;
Tb4b4b4}
T8b949e/** A WebSocket mock whose pings are never answered, to exercise pong-timeout handling. */
Tff7b72function Te6edf3makeSilentWsImplTb4b4b4(Tb4b4b4) Tb4b4b4{
Tff7b72const Te6edf3Base Tff7b72= Te6edf3makeWsImplTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72return Tff7b72class Te6edf3SilentWebSocket Tff7b72extends Te6edf3Base Tb4b4b4{
Te6edf3sendTb4b4b4(Tb4b4b4) Tb4b4b4{
T8b949e// swallow all sends (including pings) - never emit a pong
Tb4b4b4}
Tb4b4b4}Tb4b4b4;
Tb4b4b4}
T8b949e/** Minimal EventTarget-backed window mock so real focus/online/visibilitychange
* events can be dispatched and routed through addEventListener like a browser. */
Tff7b72function Te6edf3makeWindowMockTb4b4b4(Te6edf3extra Tff7b72= Tb4b4b4{Tb4b4b4}Tb4b4b4) Tb4b4b4{
Tff7b72const Te6edf3target Tff7b72= Tff7b72new Te6edf3EventTargetTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72return Tb4b4b4{
Te6edf3apiTff7b72: Tb4b4b4{Tb4b4b4}Tb4b4b4,
Te6edf3locationTff7b72: Tb4b4b4{ Te6edf3originTff7b72: Ta5d6ff"http://127.0.0.1:5173" Tb4b4b4}Tb4b4b4,
Te6edf3addEventListenerTff7b72: Te6edf3targetTb4b4b4.Te6edf3addEventListenerTb4b4b4.Te6edf3bindTb4b4b4(Te6edf3targetTb4b4b4)Tb4b4b4,
Te6edf3removeEventListenerTff7b72: Te6edf3targetTb4b4b4.Te6edf3removeEventListenerTb4b4b4.Te6edf3bindTb4b4b4(Te6edf3targetTb4b4b4)Tb4b4b4,
Te6edf3dispatchEventTff7b72: Te6edf3targetTb4b4b4.Te6edf3dispatchEventTb4b4b4.Te6edf3bindTb4b4b4(Te6edf3targetTb4b4b4)Tb4b4b4,
Tb4b4b4...Te6edf3extraTb4b4b4,
Tb4b4b4}Tb4b4b4;
Tb4b4b4}
Te6edf3describeTb4b4b4(Ta5d6ff"WebSocketConnection module"Tb4b4b4, Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{
Te6edf3beforeEachTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{
Te6edf3viTb4b4b4.Te6edf3resetModulesTb4b4b4(Tb4b4b4)Tb4b4b4;
Tffa657globalTb4b4b4.Tffa657window Tff7b72= Tb4b4b4{
Te6edf3apiTff7b72: Tb4b4b4{Tb4b4b4}Tb4b4b4,
Te6edf3locationTff7b72: Tb4b4b4{ Te6edf3originTff7b72: Ta5d6ff"http://127.0.0.1:5173" Tb4b4b4}Tb4b4b4,
Tb4b4b4}Tb4b4b4;
Tb4b4b4}Tb4b4b4)Tb4b4b4;
Te6edf3afterEachTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{
Te6edf3viTb4b4b4.Te6edf3useRealTimersTb4b4b4(Tb4b4b4)Tb4b4b4;
Tb4b4b4}Tb4b4b4)Tb4b4b4;
Te6edf3itTb4b4b4(Ta5d6ff"emits connected then disconnected on close and reconnects with backoff"Tb4b4b4, Tff7b72async Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{
Tff7b72const Te6edf3MockWS Tff7b72= Te6edf3makeWsImplTb4b4b4(Tb4b4b4)Tb4b4b4;
Tffa657globalTb4b4b4.Te6edf3WebSocket Tff7b72= Te6edf3MockWSTb4b4b4;
Te6edf3viTb4b4b4.Te6edf3useFakeTimersTb4b4b4(Tb4b4b4{ Te6edf3shouldAdvanceTimeTff7b72: Tff7b72true Tb4b4b4}Tb4b4b4)Tb4b4b4;
Tff7b72const Tb4b4b4{ Tff7b72defaultTff7b72: Te6edf3WebSocketConnection Tb4b4b4} Tff7b72= Tff7b72await Tff7b72importTb4b4b4(Ta5d6ff"../../meshchatx/src/frontend/js/WebSocketConnection.js"Tb4b4b4)Tb4b4b4;
Tff7b72const Te6edf3connected Tff7b72= Te6edf3viTb4b4b4.Te6edf3fnTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72const Te6edf3disconnected Tff7b72= Te6edf3viTb4b4b4.Te6edf3fnTb4b4b4(Tb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3onTb4b4b4(Ta5d6ff"connected"Tb4b4b4, Te6edf3connectedTb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3onTb4b4b4(Ta5d6ff"disconnected"Tb4b4b4, Te6edf3disconnectedTb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3WebSocketConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3connectedTb4b4b4.Te6edf3mockTb4b4b4.Te6edf3callsTb4b4b4.Te6edf3length Tff7b72>= T79c0ff1Tb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3connectedTb4b4b4.Te6edf3mockTb4b4b4.Te6edf3callsTb4b4b4[T79c0ff0Tb4b4b4]Tb4b4b4[T79c0ff0Tb4b4b4]Tb4b4b4)Tb4b4b4.Te6edf3toEqualTb4b4b4(Tb4b4b4{ Te6edf3isReconnectTff7b72: Tff7b72false Tb4b4b4}Tb4b4b4)Tb4b4b4;
Tff7b72const Te6edf3firstWs Tff7b72= Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4;
Te6edf3firstWsTb4b4b4.Te6edf3closeTb4b4b4(T79c0ff1000Tb4b4b4, Ta5d6ff"test"Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3disconnectedTb4b4b4.Te6edf3mockTb4b4b4.Te6edf3callsTb4b4b4.Te6edf3length Tff7b72>= T79c0ff1Tb4b4b4)Tb4b4b4;
Tff7b72const Te6edf3delay Tff7b72= T79c0ff1000Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3advanceTimersByTimeAsyncTb4b4b4(Te6edf3delay Tff7b72+ T79c0ff500Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3ws Tff7b72&& Te6edf3WebSocketConnectionTb4b4b4.Te6edf3ws Tff7b72!== Te6edf3firstWsTb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3connectedTb4b4b4.Te6edf3mockTb4b4b4.Te6edf3callsTb4b4b4.Te6edf3length Tff7b72>= T79c0ff2Tb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3connectedTb4b4b4.Te6edf3mockTb4b4b4.Te6edf3callsTb4b4b4[T79c0ff1Tb4b4b4]Tb4b4b4[T79c0ff0Tb4b4b4]Tb4b4b4)Tb4b4b4.Te6edf3toEqualTb4b4b4(Tb4b4b4{ Te6edf3isReconnectTff7b72: Tff7b72true Tb4b4b4}Tb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3destroyTb4b4b4(Tb4b4b4)Tb4b4b4;
Tb4b4b4}Tb4b4b4)Tb4b4b4;
Te6edf3itTb4b4b4(Ta5d6ff"strips pong from message stream"Tb4b4b4, Tff7b72async Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{
Tff7b72const Te6edf3MockWS Tff7b72= Te6edf3makeWsImplTb4b4b4(Tb4b4b4)Tb4b4b4;
Tffa657globalTb4b4b4.Te6edf3WebSocket Tff7b72= Te6edf3MockWSTb4b4b4;
Tff7b72const Tb4b4b4{ Tff7b72defaultTff7b72: Te6edf3WebSocketConnection Tb4b4b4} Tff7b72= Tff7b72await Tff7b72importTb4b4b4(Ta5d6ff"../../meshchatx/src/frontend/js/WebSocketConnection.js"Tb4b4b4)Tb4b4b4;
Tff7b72const Te6edf3onMessage Tff7b72= Te6edf3viTb4b4b4.Te6edf3fnTb4b4b4(Tb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3onTb4b4b4(Ta5d6ff"message"Tb4b4b4, Te6edf3onMessageTb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3WebSocketConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTff7b72?Tb4b4b4.Te6edf3readyState Tff7b72=== Te6edf3MockWSTb4b4b4.Te6edf3OPENTb4b4b4)Tb4b4b4;
Tff7b72const Te6edf3sock Tff7b72= Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4;
Te6edf3sockTb4b4b4.Te6edf3onmessageTb4b4b4(Tb4b4b4{ Te6edf3dataTff7b72: Tffa657JSONTb4b4b4.Te6edf3stringifyTb4b4b4(Tb4b4b4{ Te6edf3typeTff7b72: Ta5d6ff"pong" Tb4b4b4}Tb4b4b4) Tb4b4b4}Tb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3onMessageTb4b4b4)Tb4b4b4.Te6edf3notTb4b4b4.Te6edf3toHaveBeenCalledTb4b4b4(Tb4b4b4)Tb4b4b4;
Te6edf3sockTb4b4b4.Te6edf3onmessageTb4b4b4(Tb4b4b4{ Te6edf3dataTff7b72: Tffa657JSONTb4b4b4.Te6edf3stringifyTb4b4b4(Tb4b4b4{ Te6edf3typeTff7b72: Ta5d6ff"config"Tb4b4b4, Te6edf3configTff7b72: Tb4b4b4{Tb4b4b4} Tb4b4b4}Tb4b4b4) Tb4b4b4}Tb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3onMessageTb4b4b4)Tb4b4b4.Te6edf3toHaveBeenCalledTimesTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3destroyTb4b4b4(Tb4b4b4)Tb4b4b4;
Tb4b4b4}Tb4b4b4)Tb4b4b4;
Te6edf3itTb4b4b4(Ta5d6ff"forwards invalid JSON frames without throwing"Tb4b4b4, Tff7b72async Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{
Tff7b72const Te6edf3MockWS Tff7b72= Te6edf3makeWsImplTb4b4b4(Tb4b4b4)Tb4b4b4;
Tffa657globalTb4b4b4.Te6edf3WebSocket Tff7b72= Te6edf3MockWSTb4b4b4;
Tff7b72const Tb4b4b4{ Tff7b72defaultTff7b72: Te6edf3WebSocketConnection Tb4b4b4} Tff7b72= Tff7b72await Tff7b72importTb4b4b4(Ta5d6ff"../../meshchatx/src/frontend/js/WebSocketConnection.js"Tb4b4b4)Tb4b4b4;
Tff7b72const Te6edf3onMessage Tff7b72= Te6edf3viTb4b4b4.Te6edf3fnTb4b4b4(Tb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3onTb4b4b4(Ta5d6ff"message"Tb4b4b4, Te6edf3onMessageTb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3WebSocketConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTff7b72?Tb4b4b4.Te6edf3readyState Tff7b72=== Te6edf3MockWSTb4b4b4.Te6edf3OPENTb4b4b4)Tb4b4b4;
Tff7b72const Te6edf3sock Tff7b72= Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4;
Te6edf3expectTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3sockTb4b4b4.Te6edf3onmessageTb4b4b4(Tb4b4b4{ Te6edf3dataTff7b72: Ta5d6ff"<<<not-json>>>" Tb4b4b4}Tb4b4b4)Tb4b4b4)Tb4b4b4.Te6edf3notTb4b4b4.Te6edf3toThrowTb4b4b4(Tb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3onMessageTb4b4b4)Tb4b4b4.Te6edf3toHaveBeenCalledTimesTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3destroyTb4b4b4(Tb4b4b4)Tb4b4b4;
Tb4b4b4}Tb4b4b4)Tb4b4b4;
Te6edf3itTb4b4b4(Ta5d6ff"reconnects or pings on foreground or network change"Tb4b4b4, Tff7b72async Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{
Tff7b72const Te6edf3MockWS Tff7b72= Te6edf3makeWsImplTb4b4b4(Tb4b4b4)Tb4b4b4;
Tffa657globalTb4b4b4.Te6edf3WebSocket Tff7b72= Te6edf3MockWSTb4b4b4;
Tff7b72const Tb4b4b4{ Tff7b72defaultTff7b72: Te6edf3WebSocketConnection Tb4b4b4} Tff7b72= Tff7b72await Tff7b72importTb4b4b4(Ta5d6ff"../../meshchatx/src/frontend/js/WebSocketConnection.js"Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3WebSocketConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTff7b72?Tb4b4b4.Te6edf3readyState Tff7b72=== Te6edf3MockWSTb4b4b4.Te6edf3OPENTb4b4b4)Tb4b4b4;
Tff7b72const Te6edf3firstWs Tff7b72= Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4;
Tff7b72const Te6edf3sendSpy Tff7b72= Te6edf3viTb4b4b4.Te6edf3spyOnTb4b4b4(Te6edf3firstWsTb4b4b4, Ta5d6ff"send"Tb4b4b4)Tb4b4b4;
T8b949e// 1. If idleTime is small, it should just send a ping
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3_lastReceivedTime Tff7b72= Tffa657DateTb4b4b4.Te6edf3nowTb4b4b4(Tb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3handleForegroundOrNetworkChangeTb4b4b4(Tb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3sendSpyTb4b4b4)Tb4b4b4.Te6edf3toHaveBeenCalledTb4b4b4(Tb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4)Tb4b4b4.Te6edf3toBeTb4b4b4(Te6edf3firstWsTb4b4b4)Tb4b4b4;
T8b949e// 2. If idleTime is large, it should force a reconnect
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3_lastReceivedTime Tff7b72= Tffa657DateTb4b4b4.Te6edf3nowTb4b4b4(Tb4b4b4) Tff7b72- T79c0ff60000Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3handleForegroundOrNetworkChangeTb4b4b4(Tb4b4b4)Tb4b4b4;
T8b949e// Wait for the new WebSocket to be created and opened
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3ws Tff7b72&& Te6edf3WebSocketConnectionTb4b4b4.Te6edf3ws Tff7b72!== Te6edf3firstWsTb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4.Te6edf3readyState Tff7b72=== Te6edf3MockWSTb4b4b4.Te6edf3OPENTb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4)Tb4b4b4.Te6edf3notTb4b4b4.Te6edf3toBeTb4b4b4(Te6edf3firstWsTb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3destroyTb4b4b4(Tb4b4b4)Tb4b4b4;
Tb4b4b4}Tb4b4b4)Tb4b4b4;
Te6edf3itTb4b4b4(Ta5d6ff"reconnect() does not thrash a connection attempt that is already in flight"Tb4b4b4, Tff7b72async Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{
Tff7b72const Te6edf3MockWS Tff7b72= Te6edf3makeWsImplTb4b4b4(Tb4b4b4)Tb4b4b4;
Tffa657globalTb4b4b4.Te6edf3WebSocket Tff7b72= Te6edf3MockWSTb4b4b4;
Tff7b72const Tb4b4b4{ Tff7b72defaultTff7b72: Te6edf3WebSocketConnection Tb4b4b4} Tff7b72= Tff7b72await Tff7b72importTb4b4b4(Ta5d6ff"../../meshchatx/src/frontend/js/WebSocketConnection.js"Tb4b4b4)Tb4b4b4;
T8b949e// connect() has no internal awaits before constructing the socket,
T8b949e// so checking readyState right after calling it (without awaiting
T8b949e// the returned promise, which only settles after the queued "open"
T8b949e// microtask) reliably catches it mid-connect.
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72const Te6edf3connectingWs Tff7b72= Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3connectingWsTb4b4b4.Te6edf3readyStateTb4b4b4)Tb4b4b4.Te6edf3toBeTb4b4b4(Te6edf3MockWSTb4b4b4.Te6edf3CONNECTINGTb4b4b4)Tb4b4b4;
T8b949e// calling reconnect() again while the first attempt hasn't resolved
T8b949e// yet must not close/replace it.
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3reconnectTb4b4b4(Tb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3reconnectTb4b4b4(Tb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4)Tb4b4b4.Te6edf3toBeTb4b4b4(Te6edf3connectingWsTb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4.Te6edf3readyState Tff7b72=== Te6edf3MockWSTb4b4b4.Te6edf3OPENTb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4)Tb4b4b4.Te6edf3toBeTb4b4b4(Te6edf3connectingWsTb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3destroyTb4b4b4(Tb4b4b4)Tb4b4b4;
Tb4b4b4}Tb4b4b4)Tb4b4b4;
Te6edf3itTb4b4b4(Ta5d6ff"ignores repeated foreground/network re-triggers while a reconnect is already in flight"Tb4b4b4, Tff7b72async Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{
Tff7b72const Te6edf3MockWS Tff7b72= Te6edf3makeWsImplTb4b4b4(Tb4b4b4)Tb4b4b4;
Tffa657globalTb4b4b4.Te6edf3WebSocket Tff7b72= Te6edf3MockWSTb4b4b4;
Tff7b72const Tb4b4b4{ Tff7b72defaultTff7b72: Te6edf3WebSocketConnection Tb4b4b4} Tff7b72= Tff7b72await Tff7b72importTb4b4b4(Ta5d6ff"../../meshchatx/src/frontend/js/WebSocketConnection.js"Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3WebSocketConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTff7b72?Tb4b4b4.Te6edf3readyState Tff7b72=== Te6edf3MockWSTb4b4b4.Te6edf3OPENTb4b4b4)Tb4b4b4;
Tff7b72const Te6edf3firstWs Tff7b72= Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3_lastReceivedTime Tff7b72= Tffa657DateTb4b4b4.Te6edf3nowTb4b4b4(Tb4b4b4) Tff7b72- T79c0ff60000Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3handleForegroundOrNetworkChangeTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72const Te6edf3connectingWs Tff7b72= Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3connectingWsTb4b4b4)Tb4b4b4.Te6edf3notTb4b4b4.Te6edf3toBeTb4b4b4(Te6edf3firstWsTb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3connectingWsTb4b4b4.Te6edf3readyStateTb4b4b4)Tb4b4b4.Te6edf3toBeTb4b4b4(Te6edf3MockWSTb4b4b4.Te6edf3CONNECTINGTb4b4b4)Tb4b4b4;
T8b949e// simulate visibilitychange, focus and online all firing again
T8b949e// before the new socket has finished opening (very plausible when
T8b949e// a mobile browser/webview comes back to the foreground).
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3handleForegroundOrNetworkChangeTb4b4b4(Tb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3handleForegroundOrNetworkChangeTb4b4b4(Tb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3handleForegroundOrNetworkChangeTb4b4b4(Tb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4)Tb4b4b4.Te6edf3toBeTb4b4b4(Te6edf3connectingWsTb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4.Te6edf3readyState Tff7b72=== Te6edf3MockWSTb4b4b4.Te6edf3OPENTb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4)Tb4b4b4.Te6edf3toBeTb4b4b4(Te6edf3connectingWsTb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3destroyTb4b4b4(Tb4b4b4)Tb4b4b4;
Tb4b4b4}Tb4b4b4)Tb4b4b4;
Te6edf3itTb4b4b4(Ta5d6ff"cancels a pending backoff retry when a reconnect happens out of turn"Tb4b4b4, Tff7b72async Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{
Tff7b72const Te6edf3MockWS Tff7b72= Te6edf3makeWsImplTb4b4b4(Tb4b4b4)Tb4b4b4;
Tffa657globalTb4b4b4.Te6edf3WebSocket Tff7b72= Te6edf3MockWSTb4b4b4;
Te6edf3viTb4b4b4.Te6edf3useFakeTimersTb4b4b4(Tb4b4b4{ Te6edf3shouldAdvanceTimeTff7b72: Tff7b72true Tb4b4b4}Tb4b4b4)Tb4b4b4;
Tff7b72const Tb4b4b4{ Tff7b72defaultTff7b72: Te6edf3WebSocketConnection Tb4b4b4} Tff7b72= Tff7b72await Tff7b72importTb4b4b4(Ta5d6ff"../../meshchatx/src/frontend/js/WebSocketConnection.js"Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3WebSocketConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTff7b72?Tb4b4b4.Te6edf3readyState Tff7b72=== Te6edf3MockWSTb4b4b4.Te6edf3OPENTb4b4b4)Tb4b4b4;
Tff7b72const Te6edf3firstWs Tff7b72= Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4;
T8b949e// a real, unexpected disconnect - schedules a backoff retry
Te6edf3firstWsTb4b4b4.Te6edf3closeTb4b4b4(T79c0ff1006Tb4b4b4, Ta5d6ff"abnormal"Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3_reconnectTimeout Tff7b72!== Tff7b72nullTb4b4b4)Tb4b4b4;
T8b949e// something else (e.g. a foreground event) triggers an immediate,
T8b949e// out-of-turn reconnect before the backoff timer fires
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3reconnectTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72const Te6edf3outOfTurnWs Tff7b72= Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3outOfTurnWsTb4b4b4)Tb4b4b4.Te6edf3notTb4b4b4.Te6edf3toBeTb4b4b4(Te6edf3firstWsTb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3WebSocketConnectionTb4b4b4.Te6edf3_reconnectTimeoutTb4b4b4)Tb4b4b4.Te6edf3toBeNullTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3outOfTurnWsTb4b4b4.Te6edf3readyState Tff7b72=== Te6edf3MockWSTb4b4b4.Te6edf3OPENTb4b4b4)Tb4b4b4;
T8b949e// advance well past when the original backoff timer would have
T8b949e// fired (base delay ~1s, capped well under this), but short of the
T8b949e// next heartbeat/pong cycle so that unrelated timers don't muddy
T8b949e// the assertion. It must have been cancelled and not fire a
T8b949e// redundant second reconnect that would replace the healthy socket.
Tff7b72await Te6edf3viTb4b4b4.Te6edf3advanceTimersByTimeAsyncTb4b4b4(T79c0ff5000Tb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4)Tb4b4b4.Te6edf3toBeTb4b4b4(Te6edf3outOfTurnWsTb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4.Te6edf3readyStateTb4b4b4)Tb4b4b4.Te6edf3toBeTb4b4b4(Te6edf3MockWSTb4b4b4.Te6edf3OPENTb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3destroyTb4b4b4(Tb4b4b4)Tb4b4b4;
Tb4b4b4}Tb4b4b4)Tb4b4b4;
Te6edf3itTb4b4b4(Ta5d6ff"forceReconnect performs a silent reconnect without emitting disconnected"Tb4b4b4, Tff7b72async Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{
Tff7b72const Te6edf3MockWS Tff7b72= Te6edf3makeWsImplTb4b4b4(Tb4b4b4)Tb4b4b4;
Tffa657globalTb4b4b4.Te6edf3WebSocket Tff7b72= Te6edf3MockWSTb4b4b4;
Tff7b72const Tb4b4b4{ Tff7b72defaultTff7b72: Te6edf3WebSocketConnection Tb4b4b4} Tff7b72= Tff7b72await Tff7b72importTb4b4b4(Ta5d6ff"../../meshchatx/src/frontend/js/WebSocketConnection.js"Tb4b4b4)Tb4b4b4;
Tff7b72const Te6edf3connected Tff7b72= Te6edf3viTb4b4b4.Te6edf3fnTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72const Te6edf3disconnected Tff7b72= Te6edf3viTb4b4b4.Te6edf3fnTb4b4b4(Tb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3onTb4b4b4(Ta5d6ff"connected"Tb4b4b4, Te6edf3connectedTb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3onTb4b4b4(Ta5d6ff"disconnected"Tb4b4b4, Te6edf3disconnectedTb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3WebSocketConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTff7b72?Tb4b4b4.Te6edf3readyState Tff7b72=== Te6edf3MockWSTb4b4b4.Te6edf3OPENTb4b4b4)Tb4b4b4;
Tff7b72const Te6edf3firstWs Tff7b72= Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3_lastReceivedTime Tff7b72= Tffa657DateTb4b4b4.Te6edf3nowTb4b4b4(Tb4b4b4) Tff7b72- T79c0ff60000Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3handleForegroundOrNetworkChangeTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3ws Tff7b72&& Te6edf3WebSocketConnectionTb4b4b4.Te6edf3ws Tff7b72!== Te6edf3firstWsTb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4.Te6edf3readyState Tff7b72=== Te6edf3MockWSTb4b4b4.Te6edf3OPENTb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3disconnectedTb4b4b4)Tb4b4b4.Te6edf3notTb4b4b4.Te6edf3toHaveBeenCalledTb4b4b4(Tb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3connectedTb4b4b4)Tb4b4b4.Te6edf3toHaveBeenCalledTimesTb4b4b4(T79c0ff2Tb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3connectedTb4b4b4.Te6edf3mockTb4b4b4.Te6edf3callsTb4b4b4[T79c0ff1Tb4b4b4]Tb4b4b4[T79c0ff0Tb4b4b4]Tb4b4b4)Tb4b4b4.Te6edf3toEqualTb4b4b4(Tb4b4b4{ Te6edf3isReconnectTff7b72: Tff7b72false Tb4b4b4}Tb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3destroyTb4b4b4(Tb4b4b4)Tb4b4b4;
Tb4b4b4}Tb4b4b4)Tb4b4b4;
Te6edf3itTb4b4b4(Ta5d6ff"handleForegroundOrNetworkChange and forceReconnect are no-ops before connect() or after destroy()"Tb4b4b4, Tff7b72async Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{
Tff7b72const Te6edf3MockWS Tff7b72= Te6edf3makeWsImplTb4b4b4(Tb4b4b4)Tb4b4b4;
Tffa657globalTb4b4b4.Te6edf3WebSocket Tff7b72= Te6edf3MockWSTb4b4b4;
Tff7b72const Tb4b4b4{ Tff7b72defaultTff7b72: Te6edf3WebSocketConnection Tb4b4b4} Tff7b72= Tff7b72await Tff7b72importTb4b4b4(Ta5d6ff"../../meshchatx/src/frontend/js/WebSocketConnection.js"Tb4b4b4)Tb4b4b4;
T8b949e// never connected yet
Te6edf3expectTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3handleForegroundOrNetworkChangeTb4b4b4(Tb4b4b4)Tb4b4b4)Tb4b4b4.Te6edf3notTb4b4b4.Te6edf3toThrowTb4b4b4(Tb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3forceReconnectTb4b4b4(Tb4b4b4)Tb4b4b4)Tb4b4b4.Te6edf3notTb4b4b4.Te6edf3toThrowTb4b4b4(Tb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4)Tb4b4b4.Te6edf3toBeNullTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3WebSocketConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTff7b72?Tb4b4b4.Te6edf3readyState Tff7b72=== Te6edf3MockWSTb4b4b4.Te6edf3OPENTb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3destroyTb4b4b4(Tb4b4b4)Tb4b4b4;
T8b949e// destroyed
Te6edf3expectTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3handleForegroundOrNetworkChangeTb4b4b4(Tb4b4b4)Tb4b4b4)Tb4b4b4.Te6edf3notTb4b4b4.Te6edf3toThrowTb4b4b4(Tb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3forceReconnectTb4b4b4(Tb4b4b4)Tb4b4b4)Tb4b4b4.Te6edf3notTb4b4b4.Te6edf3toThrowTb4b4b4(Tb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4)Tb4b4b4.Te6edf3toBeNullTb4b4b4(Tb4b4b4)Tb4b4b4;
Tb4b4b4}Tb4b4b4)Tb4b4b4;
Te6edf3itTb4b4b4(Ta5d6ff"send() and ping() are safe no-ops when there is no open socket"Tb4b4b4, Tff7b72async Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{
Tff7b72const Tb4b4b4{ Tff7b72defaultTff7b72: Te6edf3WebSocketConnection Tb4b4b4} Tff7b72= Tff7b72await Tff7b72importTb4b4b4(Ta5d6ff"../../meshchatx/src/frontend/js/WebSocketConnection.js"Tb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4)Tb4b4b4.Te6edf3toBeNullTb4b4b4(Tb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3WebSocketConnectionTb4b4b4.Te6edf3sendTb4b4b4(Ta5d6ff"hello"Tb4b4b4)Tb4b4b4)Tb4b4b4.Te6edf3toBeTb4b4b4(Tff7b72falseTb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3pingTb4b4b4(Tb4b4b4)Tb4b4b4)Tb4b4b4.Te6edf3notTb4b4b4.Te6edf3toThrowTb4b4b4(Tb4b4b4)Tb4b4b4;
Tb4b4b4}Tb4b4b4)Tb4b4b4;
Te6edf3itTb4b4b4(Ta5d6ff"registers window event listeners only once across repeated connect() calls"Tb4b4b4, Tff7b72async Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{
Tff7b72const Te6edf3MockWS Tff7b72= Te6edf3makeWsImplTb4b4b4(Tb4b4b4)Tb4b4b4;
Tffa657globalTb4b4b4.Te6edf3WebSocket Tff7b72= Te6edf3MockWSTb4b4b4;
Tff7b72const Te6edf3addEventListenerSpy Tff7b72= Te6edf3viTb4b4b4.Te6edf3fnTb4b4b4(Tb4b4b4)Tb4b4b4;
Tffa657globalTb4b4b4.Tffa657window Tff7b72= Tb4b4b4{
Te6edf3apiTff7b72: Tb4b4b4{Tb4b4b4}Tb4b4b4,
Te6edf3locationTff7b72: Tb4b4b4{ Te6edf3originTff7b72: Ta5d6ff"http://127.0.0.1:5173" Tb4b4b4}Tb4b4b4,
Te6edf3addEventListenerTff7b72: Te6edf3addEventListenerSpyTb4b4b4,
Te6edf3removeEventListenerTff7b72: Te6edf3viTb4b4b4.Te6edf3fnTb4b4b4(Tb4b4b4)Tb4b4b4,
Tb4b4b4}Tb4b4b4;
Tff7b72const Tb4b4b4{ Tff7b72defaultTff7b72: Te6edf3WebSocketConnection Tb4b4b4} Tff7b72= Tff7b72await Tff7b72importTb4b4b4(Ta5d6ff"../../meshchatx/src/frontend/js/WebSocketConnection.js"Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3WebSocketConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTff7b72?Tb4b4b4.Te6edf3readyState Tff7b72=== Te6edf3MockWSTb4b4b4.Te6edf3OPENTb4b4b4)Tb4b4b4;
Tff7b72const Te6edf3countAfterFirst Tff7b72= Te6edf3addEventListenerSpyTb4b4b4.Te6edf3mockTb4b4b4.Te6edf3callsTb4b4b4.Te6edf3lengthTb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3countAfterFirstTb4b4b4)Tb4b4b4.Te6edf3toBeGreaterThanTb4b4b4(T79c0ff0Tb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3destroyTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3WebSocketConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTff7b72?Tb4b4b4.Te6edf3readyState Tff7b72=== Te6edf3MockWSTb4b4b4.Te6edf3OPENTb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3addEventListenerSpyTb4b4b4.Te6edf3mockTb4b4b4.Te6edf3callsTb4b4b4.Te6edf3lengthTb4b4b4)Tb4b4b4.Te6edf3toBeTb4b4b4(Te6edf3countAfterFirstTb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3destroyTb4b4b4(Tb4b4b4)Tb4b4b4;
Tb4b4b4}Tb4b4b4)Tb4b4b4;
Te6edf3itTb4b4b4(Ta5d6ff"only reacts to visibilitychange when the document becomes visible"Tb4b4b4, Tff7b72async Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{
Tff7b72const Te6edf3MockWS Tff7b72= Te6edf3makeWsImplTb4b4b4(Tb4b4b4)Tb4b4b4;
Tffa657globalTb4b4b4.Te6edf3WebSocket Tff7b72= Te6edf3MockWSTb4b4b4;
Tffa657globalTb4b4b4.Tffa657window Tff7b72= Te6edf3makeWindowMockTb4b4b4(Tb4b4b4)Tb4b4b4;
Tffa657globalTb4b4b4.Tffa657document Tff7b72= Tb4b4b4{ Te6edf3visibilityStateTff7b72: Ta5d6ff"hidden" Tb4b4b4}Tb4b4b4;
Tff7b72const Tb4b4b4{ Tff7b72defaultTff7b72: Te6edf3WebSocketConnection Tb4b4b4} Tff7b72= Tff7b72await Tff7b72importTb4b4b4(Ta5d6ff"../../meshchatx/src/frontend/js/WebSocketConnection.js"Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3WebSocketConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTff7b72?Tb4b4b4.Te6edf3readyState Tff7b72=== Te6edf3MockWSTb4b4b4.Te6edf3OPENTb4b4b4)Tb4b4b4;
Tff7b72const Te6edf3firstWs Tff7b72= Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3_lastReceivedTime Tff7b72= Tffa657DateTb4b4b4.Te6edf3nowTb4b4b4(Tb4b4b4) Tff7b72- T79c0ff60000Tb4b4b4;
T8b949e// still hidden - must not trigger a reconnect
Tffa657globalTb4b4b4.Tffa657windowTb4b4b4.Te6edf3dispatchEventTb4b4b4(Tff7b72new Te6edf3EventTb4b4b4(Ta5d6ff"visibilitychange"Tb4b4b4)Tb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4)Tb4b4b4.Te6edf3toBeTb4b4b4(Te6edf3firstWsTb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3firstWsTb4b4b4.Te6edf3readyStateTb4b4b4)Tb4b4b4.Te6edf3toBeTb4b4b4(Te6edf3MockWSTb4b4b4.Te6edf3OPENTb4b4b4)Tb4b4b4;
T8b949e// becoming visible should run the stale-connection check
Tffa657globalTb4b4b4.Tffa657documentTb4b4b4.Te6edf3visibilityState Tff7b72= Ta5d6ff"visible"Tb4b4b4;
Tffa657globalTb4b4b4.Tffa657windowTb4b4b4.Te6edf3dispatchEventTb4b4b4(Tff7b72new Te6edf3EventTb4b4b4(Ta5d6ff"visibilitychange"Tb4b4b4)Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3ws Tff7b72&& Te6edf3WebSocketConnectionTb4b4b4.Te6edf3ws Tff7b72!== Te6edf3firstWsTb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4.Te6edf3readyState Tff7b72=== Te6edf3MockWSTb4b4b4.Te6edf3OPENTb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4)Tb4b4b4.Te6edf3notTb4b4b4.Te6edf3toBeTb4b4b4(Te6edf3firstWsTb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3destroyTb4b4b4(Tb4b4b4)Tb4b4b4;
Tb4b4b4}Tb4b4b4)Tb4b4b4;
Te6edf3itTb4b4b4(Ta5d6ff"reacts to real focus and online DOM events"Tb4b4b4, Tff7b72async Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{
Tff7b72const Te6edf3MockWS Tff7b72= Te6edf3makeWsImplTb4b4b4(Tb4b4b4)Tb4b4b4;
Tffa657globalTb4b4b4.Te6edf3WebSocket Tff7b72= Te6edf3MockWSTb4b4b4;
Tffa657globalTb4b4b4.Tffa657window Tff7b72= Te6edf3makeWindowMockTb4b4b4(Tb4b4b4)Tb4b4b4;
Tffa657globalTb4b4b4.Tffa657document Tff7b72= Tb4b4b4{ Te6edf3visibilityStateTff7b72: Ta5d6ff"visible" Tb4b4b4}Tb4b4b4;
Tff7b72const Tb4b4b4{ Tff7b72defaultTff7b72: Te6edf3WebSocketConnection Tb4b4b4} Tff7b72= Tff7b72await Tff7b72importTb4b4b4(Ta5d6ff"../../meshchatx/src/frontend/js/WebSocketConnection.js"Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3WebSocketConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTff7b72?Tb4b4b4.Te6edf3readyState Tff7b72=== Te6edf3MockWSTb4b4b4.Te6edf3OPENTb4b4b4)Tb4b4b4;
Tff7b72const Te6edf3firstWs Tff7b72= Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4;
Tff7b72const Te6edf3sendSpy Tff7b72= Te6edf3viTb4b4b4.Te6edf3spyOnTb4b4b4(Te6edf3firstWsTb4b4b4, Ta5d6ff"send"Tb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3_lastReceivedTime Tff7b72= Tffa657DateTb4b4b4.Te6edf3nowTb4b4b4(Tb4b4b4)Tb4b4b4;
Tffa657globalTb4b4b4.Tffa657windowTb4b4b4.Te6edf3dispatchEventTb4b4b4(Tff7b72new Te6edf3EventTb4b4b4(Ta5d6ff"focus"Tb4b4b4)Tb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3sendSpyTb4b4b4)Tb4b4b4.Te6edf3toHaveBeenCalledTb4b4b4(Tb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4)Tb4b4b4.Te6edf3toBeTb4b4b4(Te6edf3firstWsTb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3_lastReceivedTime Tff7b72= Tffa657DateTb4b4b4.Te6edf3nowTb4b4b4(Tb4b4b4) Tff7b72- T79c0ff60000Tb4b4b4;
Tffa657globalTb4b4b4.Tffa657windowTb4b4b4.Te6edf3dispatchEventTb4b4b4(Tff7b72new Te6edf3EventTb4b4b4(Ta5d6ff"online"Tb4b4b4)Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3ws Tff7b72&& Te6edf3WebSocketConnectionTb4b4b4.Te6edf3ws Tff7b72!== Te6edf3firstWsTb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4.Te6edf3readyState Tff7b72=== Te6edf3MockWSTb4b4b4.Te6edf3OPENTb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4)Tb4b4b4.Te6edf3notTb4b4b4.Te6edf3toBeTb4b4b4(Te6edf3firstWsTb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3destroyTb4b4b4(Tb4b4b4)Tb4b4b4;
Tb4b4b4}Tb4b4b4)Tb4b4b4;
Te6edf3itTb4b4b4(Ta5d6ff"closes and schedules a reconnect when a heartbeat ping goes unanswered"Tb4b4b4, Tff7b72async Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{
Tff7b72const Te6edf3SilentWS Tff7b72= Te6edf3makeSilentWsImplTb4b4b4(Tb4b4b4)Tb4b4b4;
Tffa657globalTb4b4b4.Te6edf3WebSocket Tff7b72= Te6edf3SilentWSTb4b4b4;
Te6edf3viTb4b4b4.Te6edf3useFakeTimersTb4b4b4(Tb4b4b4{ Te6edf3shouldAdvanceTimeTff7b72: Tff7b72true Tb4b4b4}Tb4b4b4)Tb4b4b4;
Tff7b72const Tb4b4b4{ Tff7b72defaultTff7b72: Te6edf3WebSocketConnection Tb4b4b4} Tff7b72= Tff7b72await Tff7b72importTb4b4b4(Ta5d6ff"../../meshchatx/src/frontend/js/WebSocketConnection.js"Tb4b4b4)Tb4b4b4;
Tff7b72const Te6edf3disconnected Tff7b72= Te6edf3viTb4b4b4.Te6edf3fnTb4b4b4(Tb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3onTb4b4b4(Ta5d6ff"disconnected"Tb4b4b4, Te6edf3disconnectedTb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3WebSocketConnectionTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTff7b72?Tb4b4b4.Te6edf3readyState Tff7b72=== Te6edf3SilentWSTb4b4b4.Te6edf3OPENTb4b4b4)Tb4b4b4;
Tff7b72const Te6edf3firstWs Tff7b72= Te6edf3WebSocketConnectionTb4b4b4.Te6edf3wsTb4b4b4;
T8b949e// the very first heartbeat ping is sent on open but never answered;
T8b949e// once the pong timeout elapses the socket should be force-closed.
Tff7b72await Te6edf3viTb4b4b4.Te6edf3advanceTimersByTimeAsyncTb4b4b4(T79c0ff12000 Tff7b72+ T79c0ff500Tb4b4b4)Tb4b4b4;
Tff7b72await Te6edf3viTb4b4b4.Te6edf3waitUntilTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Te6edf3disconnectedTb4b4b4.Te6edf3mockTb4b4b4.Te6edf3callsTb4b4b4.Te6edf3length Tff7b72>= T79c0ff1Tb4b4b4)Tb4b4b4;
Te6edf3expectTb4b4b4(Te6edf3firstWsTb4b4b4.Te6edf3readyStateTb4b4b4)Tb4b4b4.Te6edf3toBeTb4b4b4(Te6edf3SilentWSTb4b4b4.Te6edf3CLOSEDTb4b4b4)Tb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3destroyTb4b4b4(Tb4b4b4)Tb4b4b4;
Tb4b4b4}Tb4b4b4)Tb4b4b4;
Tb4b4b4}Tb4b4b4)Tb4b4b4;
──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────